Skip to main content

使用Vert.x实现反向代理

1. 前言​

在简单使用Pingora后，我在想既然rust, go都能写代理相关，那为什么不用Java写一个呢？

搜了搜原来用Vert.x实现反向代理这么简单，让我们快速开始吧。

如果你想下载示例代码，可以在这里找到：demo-vertx-reverse-proxy

2. 创建Vert.x项目​

Vert.x项目的创建可以在官网找到：Create a new Vert.x application

要选择的依赖则是Vert.x Http Proxy

3. 根据Vert.x的教程开始​

官网的教程：Vert.x Http Proxy

3.1 Vert.x Http Proxy​

Vert.x Http Proxy 是基于 Vert.x 的反向代理，它旨在实现可重用的反向代理逻辑，以关注更高的问题。

该模块具有技术预览状态，这意味着 API 可以在版本之间更改。

3.2 使用 Vert.x Http Proxy​

要使用 Vert.x Http Proxy，请在pom.xml或是其他依赖配置中增加：

<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-http-proxy</artifactId>
    <version>4.1.8</version>
</dependency>

3.3 基本 Http 代理​

为了使用 Vert.x Http Proxy 完成反向代理，你需要以下内容：

  1. 代理服务器使用 HttpProxy 实例处理出站请求并将其转发给源服务器。
  2. 源服务器处理来自代理服务器的请求并相应地处理响应。

现在，你已经有了总体概念，所以让我们深入实现并从源服务器开始，然后是带有 HttpProxy 的代理服务器：

3.4 源服务​

tip

这里可以跳过，因为源服务我们可以直接使用任意你能打开的网站的链接

当然我还是保留了完整步骤。

你只需创建监听端口 7070 的源服务器

  @Override
  public void start(Promise<Void> startPromise) throws Exception {
    HttpServer originServer = vertx.createHttpServer();

    originServer.requestHandler(req -> {
      req.response()
        .putHeader("content-type", "text/html")
        .end("<html><body><h1>I'm the target resource!</h1></body></html>");
    }).listen(7070);
  }

3.5 使用 HttpProxy 的代理服务器​

使用 HttpProxy 实例创建侦听端口 8080 的代理服务器，该实例相应地处理反向代理逻辑。

  @Override
  public void start(Promise<Void> startPromise) throws Exception {
    HttpClient proxyClient = vertx.createHttpClient();

    HttpProxy proxy = HttpProxy.reverseProxy(proxyClient);
    proxy.origin(7070, "origin");

    HttpServer proxyServer = vertx.createHttpServer();

    proxyServer.requestHandler(proxy).listen(8080);
  }

最后，所有向外发出的请求都将作为反向代理方便地转发给源服务器。

官方教程到这里就结束了，只是代理某个ip+端口的服务，但是如果想代理某个网站呢？

4. 代理网站​

代理某个网站的话，我们需要其实需要代理的是那个网站url+443端口，以及信任网站的证书

所以我们的verticle实现需要改一下，这里我直接使用了自己的博客链接，你可以改为任意地址

  @Override
  public void start(Promise<Void> startPromise) throws Exception {
    HttpClient proxyClient = vertx.createHttpClient(new HttpClientOptions().setSsl(true).setTrustAll(true));

    // 创建一个 HttpProxy 实例
    HttpProxy proxy = HttpProxy.reverseProxy(proxyClient);
    // 配置目标服务器和端口
    proxy.origin(443, "runnable.run");
    // 设置 HttpServer 监听请求
    HttpServer proxyServer = vertx.createHttpServer();

    proxyServer.requestHandler(req -> {
      // 在此给请求添加 Host 头部
      req.headers().set("Host", "runnable.run");

      // 通过 HttpClient 转发请求到目标服务器
      proxy.handle(req);
    }).listen(8080, res -> {
      if (res.succeeded()) {
        System.out.println("Proxy server is running on port 8080， http://localhost:8080");
        startPromise.complete();
      } else {
        startPromise.fail(res.cause());
      }
    });
  }

然后给服务增加一个main方法启动试试

  public static void main(String[] args) {
    VertxOptions vertxOptions = new VertxOptions();
    Vertx vertx  = Vertx.vertx(vertxOptions);
    DeploymentOptions deploymentOptions = new DeploymentOptions();
    vertx.deployVerticle(new MainVerticle(), deploymentOptions);
  }

4.1 完整代码如下​

package run.runnable.demo_vertx_reverse_proxy;

import io.vertx.core.*;
import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpServer;
import io.vertx.httpproxy.HttpProxy;

public class MainVerticle extends AbstractVerticle {

  @Override
  public void start(Promise<Void> startPromise) throws Exception {
    HttpClient proxyClient = vertx.createHttpClient(new HttpClientOptions().setSsl(true).setTrustAll(true));

    // 创建一个 HttpProxy 实例
    HttpProxy proxy = HttpProxy.reverseProxy(proxyClient);
    // 配置目标服务器和端口
    proxy.origin(443, "runnable.run");
    // 设置 HttpServer 监听请求
    HttpServer proxyServer = vertx.createHttpServer();

    proxyServer.requestHandler(req -> {
      // 在此给请求添加 Host 头部
      req.headers().set("Host", "runnable.run");

      // 通过 HttpClient 转发请求到目标服务器
      proxy.handle(req);
    }).listen(8080, res -> {
      if (res.succeeded()) {
        System.out.println("Proxy server is running on port 8080， http://localhost:8080");
        startPromise.complete();
      } else {
        startPromise.fail(res.cause());
      }
    });
  }

  public static void main(String[] args) {
    VertxOptions vertxOptions = new VertxOptions();
    Vertx vertx  = Vertx.vertx(vertxOptions);
    DeploymentOptions deploymentOptions = new DeploymentOptions();
    vertx.deployVerticle(new MainVerticle(), deploymentOptions);
  }
}

启动之后，使用浏览器打开 http://localhost:8080 就会发现已经是博客的页面了。所以如果你把这个反向代理在香港服务器部署，链接替换为google就。。。